from multiprocessing import Pool
import time
import os

def funa(index):
    time.sleep(1)
    print(f"{os.getpid()}在执行任务数{index}")  # os.getpid()当前进程编号

if __name__ == '__main__':
    p = Pool(5)  # 创建进程池并且指定3个进程数：方便管理，减少开销
    for i in range(1,11):
        p.apply_async(func=funa,args=(i,))
    # p.terminate() # 终止子进程
    p.close()  # 关闭进程池
    p.join() # 阻塞主进程：进程池里面默认是守护线程
    print("结束了")
